package com.dingding.queue.queue.consumer;

public abstract class AbstractManager extends AbstractConsumer {

	/**
	 * 添加需要订阅的消费者到集合中
	 * @Title: addConsumer 
	 * @author CHEHAUNBO
	 * 
	 */
	public abstract void addConsumer(AbstractConsumer abstractConsumer);

	/**
	 * 
	 * 通知消费者订阅主题
	 * 
	 * @Title: notifyConsumer 
	 * @author CHEHAUNBO
	 * 
	 */
	public abstract void notifyConsumer();

}
